orblivion

    subscribeSink_ fun =
      awaitForever $ (\x -> 
                       case decode (L.fromStrict x) of
                         Just (SubscribeResponse (resp, _)) -> do
                           _ <- liftIO $ mapM (onMsg subOpts . fun) resp
                           return ()
                         Nothing ->
                           return ())

    subscribeSink = subscribeSink_ id