Applications need to be able to create a fake subscriber session, streaming fake handlers.

• Mocking for AtLeastOnce
• Mocking for ExactlyOnce
• Mocking/faking for Session
  • consider having futures::Stream in the interface and gating it with a #[cfg(unstable-stream)]
  • or we have to wrap futures::Stream. 🤷