code: def test_window_full():
      df = cudf.DataFrame(
          {"x": np.arange(10, dtype=float), "y": [1.0, 2.0] * 5}
      )
  
      sdf = DataFrame(example=df)
  
      L = sdf.window(n=4).apply(lambda x: x).stream.sink_to_list()
  
      sdf.emit(df.iloc[:3])
      sdf.emit(df.iloc[3:8])
      sdf.emit(df.iloc[8:])
  
      assert_eq(L[0], df.iloc[:3])
      assert_eq(L[1], df.iloc[4:8])
      assert_eq(L[2], df.iloc[-4:])
  
imports: import json
  import operator
  import numpy
  import pandas
  import pytest
  from dask.dataframe.utils import assert_eq
  from distributed import Client
  from streamz import Stream
  from streamz.dask import DaskStream
  from streamz.dataframe import Aggregation, DataFrame, DataFrames, Series
label_desc: Use image node_id 36 for calling a global function with example usage: test_window_full() without return types