Replace int Streamtype property with enum

docs/workflows/GettingStarted-SubscribedFetch.bonsai

@@ -14,10 +14,10 @@
       </Expression>
       <Expression xsi:type="Combinator">
         <Combinator xsi:type="glx:Fetch">
-          <glx:BufferLength>1000</glx:BufferLength>
           <glx:Host>localhost</glx:Host>
           <glx:Port>4142</glx:Port>
-          <glx:StreamType>0</glx:StreamType>
+          <glx:BufferLength>1000</glx:BufferLength>
+          <glx:StreamType>Daq</glx:StreamType>
           <glx:Substream>0</glx:Substream>
           <glx:Channels>
             <glx:int>0</glx:int>

docs/workflows/GettingStarted-UnsubscribedFetch.bonsai

@@ -7,10 +7,10 @@
     <Nodes>
       <Expression xsi:type="Combinator">
         <Combinator xsi:type="glx:Fetch">
-          <glx:BufferLength>1000</glx:BufferLength>
           <glx:Host>localhost</glx:Host>
           <glx:Port>4142</glx:Port>
-          <glx:StreamType>0</glx:StreamType>
+          <glx:BufferLength>1000</glx:BufferLength>
+          <glx:StreamType>Daq</glx:StreamType>
           <glx:Substream>0</glx:Substream>
           <glx:Channels>
             <glx:int>0</glx:int>

src/Bonsai.SpikeGLX/Fetch.cs

@@ -38,10 +38,10 @@ public class Fetch : Source<Mat>
         public int BufferLength { get; set; } = 1000;
 
         /// <summary>
-        /// Gets or sets the stream type (0: NIDAQ, 1: Onebox, 2: IMEC Probe).
+        /// Gets or sets the stream type (0: Daq, 1: Onebox, 2: Probe).
         /// </summary>
-        [Description("Stream type (0: NIDAQ, 1: Onebox, 2: IMEC Probe).")]
-        public int StreamType { get; set; } = 0;
+        [Description("Stream type (0: Daq, 1: Onebox, 2: Probe).")]
+        public StreamType StreamType { get; set; } = StreamType.Daq;
 
         /// <summary>
         /// Gets or sets the substream (0 for NIDAQ, probe number for IMEC Probe).
@@ -98,7 +98,7 @@ public override IObservable<Mat> Generate()
                 return Task.Factory.StartNew(() =>
                 {
                     // Establish connection to SpikeGLX command server.
-                    using SpikeGLXDataStream connection = new(Host, Port, StreamType, Substream, Channels);
+                    using SpikeGLXDataStream connection = new(Host, Port, (int)StreamType, Substream, Channels);
 
                     // Get the sample rate of the stream and use it to convert the buffer length,
                     // in ms, to a buffer size, in number of elements.
@@ -158,7 +158,7 @@ public IObservable<Mat> Generate<TSource>(IObservable<TSource> source)
         {
             // Create a disposable data stream connection using the provided host, port, stream type, substream, and channels.
             return Observable
-                .Using<Mat, SpikeGLXDataStream>(() => new SpikeGLXDataStream(Host, Port, StreamType, Substream, Channels),
+                .Using<Mat, SpikeGLXDataStream>(() => new SpikeGLXDataStream(Host, Port, (int)StreamType, Substream, Channels),
                     // Use the data stream connection to fetch the latest data for each input notification.
                     connection => source
                         .Select(input =>
@@ -175,4 +175,25 @@ public IObservable<Mat> Generate<TSource>(IObservable<TSource> source)
                 .RefCount();
         }
     }
+
+    /// <summary>
+    /// Specifies possible values for the SpikeGLX stream
+    /// </summary>
+    public enum StreamType
+    {
+        /// <summary>
+        /// NIDAQ.
+        /// </summary>
+        Daq = 0,
+
+        /// <summary>
+        /// Onebox.
+        /// </summary>
+        OneBox = 1,
+
+        /// <summary>
+        /// IMEC probe.
+        /// </summary>
+        Probe = 2
+    }
 }