grpc-dart icon indicating copy to clipboard operation
grpc-dart copied to clipboard

Support .map() that returns ResponseStream instead of Stream

Open maherjaafar opened this issue 1 year ago • 6 comments

keeping the return type as ReponseStream to be able to call .cancel() after using .map()

Used version: grpc: 3.2.4

Example

    final ReponseStream myStream = _client
        .myReponseStream
        .listen((event) => event.map((event) => event.value));

Expected result: I expect to get result of type ReponseStream but the result will be of type Stream

Actual result: Stream

maherjaafar avatar Jan 31 '24 14:01 maherjaafar

Any updates?

maherjaafar avatar Feb 20 '24 09:02 maherjaafar

@mosuem any updates?

maherjaafar avatar Apr 19 '24 09:04 maherjaafar

Hi @maherjaafar, I am not sure what you mean. Where does this WatchEventsRequest come from?

mosuem avatar Apr 19 '24 09:04 mosuem