úÎ!*Ç(W     SafeÅstore-streaming#Type used to store the length of a Message.store-streaming6Some fixed arbitrary magic number that precedes every Message.!A thin streaming layer that uses  for serialisation.None>_'tstore-streamingbWe use this type as a more descriptive unit to signal that more input should be read from the Fd.LThis data-type is only available on POSIX systems (essentially, non-windows)store-streaming$Given some sort of input, fills the  with it.The K is how many bytes we'd like: this is useful when the filling function is  fillFromFd", where we can specify a max size.store-streamingyThe result of peeking at the next message can either be a successfully deserialised object, or a request for more input. store-streamingIf a is an instance of ,  Message a< can be serialised and deserialised in a streaming fashion. store-streaming Encode a   to a .store-streamingDecode a value, given a ; and the number of bytes that make up the encoded message.store-streaming'Read and check the magic number from a  store-streaming Decode a  from a . store-streamingDecode some object from a 9, by first reading its header, and then the actual data.store-streaming Decode a   from a S and an action that can get additional inputs to refill the buffer when necessary.8The only conditions under which this function will give !, is when the , contains zero bytes, and refilling yields !H. If there is some data available, but not enough to decode the whole  , a " will be thrown.store-streaming Decode some   from a 4, by first reading its header, and then the actual  .store-streaming&Peeks a message from a _non blocking_ #.KThis function is only available on POSIX systems (essentially, non-windows)store-streamingDecodes all the message using  registerFd to find out when a Socket is ready for reading.KThis function is only available on POSIX systems (essentially, non-windows)store-streamingConduit for encoding  s to s.store-streamingConduit for decoding  s from s.store-streaming_NOTE: ignore the conduit deprecation warning. Otherwise incompatible with old conduit versionsstore-streamingInitial length of the " used for buffering the incoming s. If ! , use the default value of 4MB.store-streamingaNOTE: ignore the conduit deprecation warning. Otherwise incompatible with old conduit versions.   Safe(2$%&'()*+,        !"#$%&'()*+',-./0'123456789:;.store-streaming-0.2.0.3-4XNgcIhiICw1RFO287r7DaData.Store.Streaming.InternalData.Store.StreamingPaths_store_streamingSizeTag messageMagic magicLength sizeTagLength headerLength ReadMoreDataFillByteBuffer PeekMessageMessage fromMessage encodeMessage peekMessage decodeMessage peekMessageBSdecodeMessageBS peekMessageFddecodeMessageFd conduitEncode conduitDecode $fEqMessage $fShowMessage$fEqReadMoreData$fShowReadMoreData"store-0.7.7-CjGN38HkGnTDscQwyM9e6wData.Store.ImplStoreSystem.IO.ByteBuffer ByteBufferghc-prim GHC.TypesIntbytestring-0.10.8.2Data.ByteString.Internal ByteString decodeFromPtrbaseGHC.PtrPtrpeekMessageMagicpeekMessageSizeTag GHC.MaybeNothing)store-core-0.4.4.3-E53oh2CvUd66boU0bATjkGData.Store.Core PeekExceptionSystem.Posix.TypesFdversion getBinDir getLibDir getDynLibDir getDataDir getLibexecDir getSysconfDirgetDataFileName