code: def test_split_online_stream_continuous_linear_decay(self):
      num_exp, num_classes = 5, 10
      d1, d2 = dummy_classification_datasets(n_classes=num_classes)
      bm = class_incremental_benchmark(
          {"train": d1, "test": d2}, num_experiences=num_exp
      )
  
      iter_per_virt_epoch = 100
      ocl_stream = split_continuous_linear_decay_stream(
          bm.train_stream,
          experience_size=10,
          iters_per_virtual_epoch=100,
          beta=0.5,
          shuffle=True,
      )
  
      expected_length = len(bm.train_stream) * iter_per_virt_epoch
      n_exps = 0
      all_classes = set()
      for exp in ocl_stream:
          assert len(exp.dataset) == 10
          n_exps += 1
          all_classes.update(set(exp.dataset.targets))
  
      # Check the length of the stream
      assert n_exps == expected_length
  
      # Check if all classes in the dataset are present in the stream
      assert len(all_classes) == num_classes
  
file_path: avalanche/tests/benchmarks/scenarios/test_online_scenario.py
imports: import unittest
  from avalanche.benchmarks.scenarios.online import OnlineCLScenario
  from avalanche.benchmarks.scenarios.supervised import class_incremental_benchmark
  from tests.unit_tests_utils import dummy_classification_datasets, get_fast_benchmark
  from avalanche.benchmarks.scenarios.online import split_online_stream, split_continuous_linear_decay_stream
label_desc: Use image node_id 5 for calling the OCLTests obj's underlying member method code with example usage: obj.test_split_online_stream_continuous_linear_decay() without return types