Îõ³h& v ™      Safe-Inferred8store-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. Safe-Inferred"Âã Estore-streamingâWe use this type as a more descriptive unit to signal that more input should be read from the Fd.ÌThis data-type is only available on POSIX systems (essentially, non-windows)store-streaming$Given some sort of input, fills the  with it.The Ë is how many bytes we'd like: this is useful when the filling function is  fillFromFd", where we can specify a max size.store-streamingùThe 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 Ó 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 !È. 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_ #.ËThis 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.ËThis 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-streamingáNOTE: ignore the conduit deprecation warning. Otherwise incompatible with old conduit versions.    Safe-Inferred Œ$%&'()*+,        !"#$%&'()*+',-./0'123456789:;.store-streaming-0.2.0.4-7lFNgXkLG6nHUfUyqAo2JhData.Store.Streaming.InternalData.Store.StreamingPaths_store_streamingSizeTag messageMagic magicLength sizeTagLength headerLength ReadMoreDataFillByteBuffer PeekMessageMessage fromMessage encodeMessage peekMessage decodeMessage peekMessageBSdecodeMessageBS peekMessageFddecodeMessageFd conduitEncode conduitDecode$fEqReadMoreData$fShowReadMoreData $fEqMessage $fShowMessage"store-0.7.17-pJMjuLiViiKRG3L9SgOp7Data.Store.ImplStoreSystem.IO.ByteBuffer ByteBufferghc-prim GHC.TypesIntbytestring-0.11.3.1Data.ByteString.Internal ByteString decodeFromPtrbaseGHC.PtrPtrpeekMessageMagicpeekMessageSizeTag GHC.MaybeNothing)store-core-0.4.4.5-2ISqBcYGakOBQLXXxiDCfAData.Store.Core PeekExceptionSystem.Posix.TypesFdversiongetDataFileName getBinDir getLibDir getDynLibDir getDataDir getLibexecDir getSysconfDir