code: def test_rolling_count_aggregations(
      op, window, m, pre_get, post_get, kwargs, stream
  ):
      index = pd.DatetimeIndex(
          pd.date_range("2000-01-01", "2000-01-03", freq="1h")
      )
      df = cudf.DataFrame({"x": np.arange(len(index))}, index=index)
  
      expected = getattr(post_get(pre_get(df).rolling(window)), op)(
          **kwargs
      )
  
      sdf = DataFrame(example=df, stream=stream)
      roll = getattr(post_get(pre_get(sdf).rolling(window)), op)(
          **kwargs
      )
      L = roll.stream.gather().sink_to_list()
      assert len(L) == 0
  
      for i in range(0, len(df), m):
          sdf.emit(df.iloc[i : i + m])
  
      assert len(L) > 1
  
      assert_eq(cudf.concat(L), expected)
  
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 21 for calling a global function with example usage: test_rolling_count_aggregations(op, window, m, pre_get, post_get, kwargs, stream) without return types