@spec ask(GRPC.Stream.t(), pid() | atom(), non_neg_integer()) ::
  GRPC.Stream.t() | {:error, :timeout | :process_not_alive}

@spec ask!(GRPC.Stream.t(), pid() | atom(), non_neg_integer()) :: GRPC.Stream.t()

@spec effect(GRPC.Stream.t(), (term() -> term())) :: GRPC.Stream.t()

@spec filter(GRPC.Stream.t(), (term() -> term())) :: GRPC.Stream.t()

@spec flat_map(GRPC.Stream.t(), (term() -> Enumerable.GRPCStream.t())) ::
  GRPC.Stream.t()

@spec map(GRPC.Stream.t(), (term() -> term())) :: GRPC.Stream.t()

@spec map_error(GRPC.Stream.t(), (reason() -> term())) :: GRPC.Stream.t()

@spec map_with_context(GRPC.Stream.t(), (map(), term() -> term())) :: GRPC.Stream.t()

@spec partition(
  GRPC.Stream.t(),
  keyword()
) :: GRPC.Stream.t()

@spec reduce(GRPC.Stream.t(), (-> acc), (term(), acc -> acc)) :: GRPC.Stream.t()
when acc: term()

@spec reject(GRPC.Stream.t(), (term() -> term())) :: GRPC.Stream.t()

@spec uniq(GRPC.Stream.t()) :: GRPC.Stream.t()

@spec uniq_by(GRPC.Stream.t(), (term() -> term())) :: GRPC.Stream.t()