pub trait StreamSink: Stream<Item = Result<BytesMut, Error>> + Sink<Bytes, Error = Error> { }
deploy_integration