/** * Create a sink which publishes each element to the specified hub. * * @tsplus static effect/core/stream/Sink.Ops fromHub */ export function fromHub(hub: Hub): Sink { return Sink.fromQueue(hub) }