Function spawn_event_pipe_with_handle 

pub fn spawn_event_pipe_with_handle<EVT: Send + Sync + Unpin + 'static, E, SPAWNER: Spawn, SOURCE: EventSource<EVT> + 'static, SINK: EventSink<EVT, Error = E> + Send + Sync + 'static>(
    spawner: &SPAWNER,
    source: &SOURCE,
    sink: SINK,
    error_handler: impl FnOnce(E) + Send + 'static,
) -> Result<RemoteHandle<()>, SpawnError>

Same as spawn_event_pipe, but also returns handle to task spawned by futures::task::SpawnExt::spawn_with_handle