Sarsi.Consumer
consumeOrWait :: Topic -> (Maybe s -> IOSource Event -> IO (Either s a)) -> IO a Source #
consume :: Topic -> (Maybe s -> IOSource Event -> IO (Either s a)) -> IO (Either IOException a) Source #
consume' :: Topic -> (Maybe s -> IOSource Event -> IO (Either s a)) -> IO a Source #