236: def dispatch_query_message msg
237: case msg
238: when DataRow
239: @r.rows << msg.columns
240: when CommandComplete
241: @r.cmd_tag = msg.cmd_tag
242: when ReadyForQuery
243: pq,@pending_query = @pending_query,nil
244: pq.succeed true, @r, @e
245: when RowDescription
246: @r.fields = msg.fields
247: when CopyInResponse
248: when CopyOutResponse
249: when EmptyQueryResponse
250: when ErrorResponse
251:
252: @e << msg
253: when NoticeResponse
254: @notice_processor.call(msg) if @notice_processor
255: else
256:
257: end
258: end