222: def dispatch_query_message msg
223: case msg
224: when DataRow
225: @r.rows << msg.columns
226: when CommandComplete
227: @r.cmd_tag = msg.cmd_tag
228: when ReadyForQuery
229: pq,@pending_query = @pending_query,nil
230: pq.succeed true, @r, @e
231: when RowDescription
232: @r.fields = msg.fields
233: when CopyInResponse
234: when CopyOutResponse
235: when EmptyQueryResponse
236: when ErrorResponse
237:
238: @e << msg
239: when NoticeResponse
240: @notice_processor.call(msg) if @notice_processor
241: else
242:
243: end
244: end