module Database.Edis.Command.PubSub (
Database.Edis.Command.PubSub.publish
, Database.Edis.Command.PubSub.pubSub
, subscribe
, unsubscribe
, psubscribe
, punsubscribe
) where
import Database.Edis.Type
import Data.ByteString (ByteString)
import Database.Redis as Redis hiding (decode)
publish :: ByteString -> ByteString -> Edis xs xs (Either Reply Integer)
publish channel message = Edis $ Redis.publish channel message
pubSub :: PubSub -> (Message -> IO PubSub) -> Edis xs xs ()
pubSub initSub callback = Edis $ Redis.pubSub initSub callback