@@ -185,6 +185,29 @@ def test_flush_4(self):
185185 sender .row ('tbl1' , symbols = {'a' : 'b' })
186186 sender .flush (buffer = None , clear = False )
187187
188+ def test_two_rows_explicit_buffer (self ):
189+ with Server () as server , qi .Sender ('localhost' , server .port ) as sender :
190+ server .accept ()
191+ self .assertEqual (server .recv (), [])
192+ buffer = sender .new_buffer ()
193+ buffer .row (
194+ 'line_sender_buffer_example2' ,
195+ symbols = {'id' : 'Hola' },
196+ columns = {'price' : '111222233333i' , 'qty' : 3.5 },
197+ at = qi .TimestampNanos (111222233333 ))
198+ buffer .row (
199+ 'line_sender_example' ,
200+ symbols = {'id' : 'Adios' },
201+ columns = {'price' : '111222233343i' , 'qty' : 2.5 },
202+ at = qi .TimestampNanos (111222233343 ))
203+ exp = (
204+ 'line_sender_buffer_example2,id=Hola price="111222233333i",qty=3.5 111222233333\n '
205+ 'line_sender_example,id=Adios price="111222233343i",qty=2.5 111222233343\n ' )
206+ self .assertEqual (str (buffer ), exp )
207+ sender .flush (buffer )
208+ msgs = server .recv ()
209+ bexp = [msg .encode ('utf-8' ) for msg in exp .rstrip ().split ('\n ' )]
210+ self .assertEqual (msgs , bexp )
188211
189212 def test_independent_buffer (self ):
190213 buf = qi .Buffer ()
0 commit comments