type SubscriptionStream<S> = Map<S, fn(_: <S as Stream>::Item) -> Result<<S as Stream>::Item, Error>>;

Aliased Type§

struct SubscriptionStream<S> {
    stream: S,
    f: fn(_: <S as Stream>::Item) -> Result<<S as Stream>::Item, Error>,
}

Fields§

§stream: S§f: fn(_: <S as Stream>::Item) -> Result<<S as Stream>::Item, Error>