Documentation

messageLines :: ByteString -> ([ByteString], ByteString) Source #

parseInMessage :: ByteString -> InMessage Value Source #

publishAsInMessage :: Member (Queue (InMessage Value)) r => ByteString -> Sem r () Source #

concatMessages :: ByteString -> [ByteString] -> ByteString -> (ByteString, [ByteString]) Source #

accumulateMessages :: ByteString -> ByteString -> (ByteString, [ByteString]) Source #

readQueue :: forall r. Members [Queue (InMessage Value), Embed IO] r => Socket -> Sem r () Source #

writeQueue :: forall r. Members [Queue (OutMessage Value), Log, Embed IO] r => Socket -> Sem r () Source #

interpretQueues :: Members [Resource, Race, Embed IO] r => TBMQueue (OutMessage fmt) -> TBMQueue (InMessage fmt) -> InterpretersFor [Queue (InMessage fmt), Queue (OutMessage fmt)] r Source #

withSocketQueues :: Members [Resource, Async, Race, Log, Embed IO] r => MpvResources Value -> InterpretersFor [Queue (InMessage Value), Queue (OutMessage Value)] r Source #