Pseudo Online evaluation and dataset conversion

docs/source/whats_new.rst

@@ -17,6 +17,8 @@ Develop branch
 
 Enhancements
 ~~~~~~~~~~~~
+- Increasing the version in the pre-commit config (:gh:`631` by pre-commit bot)
+- Implementation of Pseudo Online framework (:gh:`641` by `Igor Carrara`_)
 
 - Update version of pyRiemann to 0.7 (:gh:`671` by `Gregoire Cattan`_)
 
@@ -44,6 +46,7 @@ Enhancements
 - Add new dataset :class:`moabb.datasets.Liu2024` dataset (:gh:`619` by `Taha Habib`_)
 
 
+
 Bugs
 ~~~~
 - Fix caching in the workflows (:gh:`632` by `Pierre Guetschel`_)

examples/plot_pseudoonline.py

@@ -0,0 +1,60 @@
+# Set up the Directory for made it run on a server.
+
+import numpy as np
+from pyriemann.classification import MDM, FgMDM
+from pyriemann.estimation import Covariances
+from sklearn.pipeline import Pipeline
+
+from moabb.datasets import BNCI2014_001
+from moabb.evaluations import WithinSessionEvaluation
+from moabb.paradigms import MotorImagery
+
+
+sub = 1
+
+# Initialize parameter for the Band Pass filter
+fmin = 8
+fmax = 30
+tmax = 3
+
+# Load Dataset and switch to Pseudoonline mode
+dataset = BNCI2014_001()
+dataset.pseudoonline = True
+
+# events = ["right_hand", "left_hand"]
+events = list(dataset.event_id.keys())
+
+paradigm = MotorImagery(
+    events=events, n_classes=len(events), fmin=fmin, fmax=fmax, tmax=tmax, overlap=50
+)
+
+X, y, meta = paradigm.get_data(dataset=dataset, subjects=[sub])
+print("Print Events_id:", y)
+unique, counts = np.unique(y, return_counts=True)
+print("Number of events per class:", dict(zip(unique, counts)))
+
+
+pipelines = {}
+pipelines["MDM"] = Pipeline(
+    steps=[
+        ("Covariances", Covariances("cov")),
+        ("MDM", MDM(metric=dict(mean="riemann", distance="riemann"))),
+    ]
+)
+
+pipelines["FgMDM"] = Pipeline(
+    steps=[("Covariances", Covariances("cov")), ("FgMDM", FgMDM())]
+)
+
+dataset.subject_list = dataset.subject_list[int(sub) - 1 : int(sub)]
+# Select an evaluation Within Session
+evaluation_online = WithinSessionEvaluation(
+    paradigm=paradigm, datasets=dataset, overwrite=True, random_state=42, n_jobs=1
+)
+
+# Print the results
+results_ALL = evaluation_online.process(pipelines)
+results_pipeline = results_ALL.groupby(["pipeline"], as_index=False)["score"].mean()
+results_pipeline_std = results_ALL.groupby(["pipeline"], as_index=False)["score"].std()
+results_pipeline["std"] = results_pipeline_std["score"]
+print(results_pipeline)

moabb/datasets/base.py

@@ -319,6 +319,7 @@ def __init__(
         paradigm,
         doi=None,
         unit_factor=1e6,
+        overlap=False,
     ):
         """Initialize function for the BaseDataset."""
         try:
@@ -348,6 +349,7 @@ def __init__(
         self.paradigm = paradigm
         self.doi = doi
         self.unit_factor = unit_factor
+        self.overlap = overlap
 
     def _create_process_pipeline(self):
         return Pipeline(