code: def test_split_online_stream_drop_last(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
      )
      online_train_stream = split_online_stream(
          bm.train_stream, experience_size=10, drop_last=True
      )
      cnt_is_first = 0
      cnt_is_last = 0
      for exp in online_train_stream:
          if exp.is_first_subexp:
              cnt_is_first += 1
          if exp.is_last_subexp:
              cnt_is_last += 1
          assert len(exp.dataset) == 10
  
      assert (
          exp.is_last_subexp
      )  # final exp should have is_last_subexp == True
      assert cnt_is_last == len(bm.train_stream)
      assert cnt_is_first == len(bm.train_stream)
  
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 3 for calling the OCLTests obj's underlying member method code with example usage: obj.test_split_online_stream_drop_last() without return types