необходимость в "трубе" в процессе

Question

У меня есть следующий код:

public  override async Task<Empty> MirrorFull(IAsyncStreamReader<StringPayload> requestStream, ServerCallContext context)
        {

            MyQueueHandler fqh = new MyQueueHandler(...);
            while(await requestStream.MoveNext(CancellationToken.None))
            {
                logger.Debug($"**RECEIVE MIRROR MESSAGE FOR FULL**");
                //I've read a string from source stream reader, i need to push on the fqh stream...
            }
            return new Empty();
        }

так что я на сервере gRPC, который получает поток строк от gRPC. Обработчик очереди имеет функцию:

public override async Task  ConsumeAsync(Stream stream)

Я хочу "непрерывно" передать полученную строку в ConsumeAsync, поэтому мне нужен какой-то PipeStream, но я не нашел его (по-видимому, класс PipeStream - это не то, что мне нужно), как я могу это сделать?