rethinkdb-client-driver 0.0.6 → 0.0.7

raw patch · 3 files changed

+11/−3 lines, 3 files

Files

• rethinkdb-client-driver.cabal +1/−1
• src/Database/RethinkDB.hs +6/−1
• src/Database/RethinkDB/Messages.hs +4/−1

@@ -1,5 +1,5 @@ name:                   rethinkdb-client-driver-version:                0.0.6+version:                0.0.7 license:                MIT license-file:           LICENSE author:                 Tomas Carnecky

@@ -3,7 +3,7 @@  module Database.RethinkDB     ( Handle-    , defaultPort, newHandle+    , defaultPort, newHandle, close     , run, nextChunk, collect, stop, wait      , Error(..)@@ -76,6 +76,11 @@     ref <- newIORef 1      return $ Handle sock ref db+++-- | Close the given handle. You MUST NOT use the handle after this.+close :: Handle -> IO ()+close handle = closeSocket (hSocket handle)   -- | Start a new query and wait for its (first) result. If the result is an

@@ -19,7 +19,7 @@ import           Data.Binary.Get as Get  import           Network.Socket (Socket, AddrInfo(..), AddrInfoFlag(..), SocketType(..))-import           Network.Socket (getAddrInfo, socket, connect, defaultHints)+import           Network.Socket (getAddrInfo, socket, connect, close, defaultHints)  import           Network.Socket.ByteString      (recv) import           Network.Socket.ByteString.Lazy (sendAll)@@ -37,6 +37,9 @@   where     hints = defaultHints { addrSocketType = Stream, addrFlags = [ AI_NUMERICSERV ] } ++closeSocket :: Socket -> IO ()+closeSocket = close   sendMessage :: Socket -> BS.ByteString -> IO ()