FS2 who to do a onCancelWith

I have a grpc service which ofer an API looking like that def f(input: fs2.Stream[F, Input]) : fs2.Stream[F, Output]

How to force pull in fs2.Stream

I created an fs2.Stream with: