(self)
| 12 | self.df = pd.DataFrame([[1, 2], [3, 4], [5, 6]], columns=['x', 'y']) |
| 13 | |
| 14 | def test_pipe_stream(self): |
| 15 | stream = Pipe(data=self.df) |
| 16 | plot = self.df.hvplot('x', 'y', stream=stream) |
| 17 | pd.testing.assert_frame_equal(plot[()].data, self.df) |
| 18 | new_df = pd.DataFrame([[7, 8], [9, 10]], columns=['x', 'y']) |
| 19 | stream.send(new_df) |
| 20 | pd.testing.assert_frame_equal(plot[()].data, new_df) |
| 21 | |
| 22 | def test_buffer_stream(self): |
| 23 | stream = Buffer(data=self.df, index=False) |