Make stream class MCU and OS agnostic

Author: h2zero

examples/NimBLE_Stream_Client/NimBLE_Stream_Client.ino

@@ -124,14 +124,6 @@ bool connectToServer() {
         return false;
     }
 
-    /** Start the stream (begins internal buffers and tasks) */
-    if (!bleStream.begin()) {
-        Serial.println("Failed to start BLE stream!");
-        bleStream.deinit();
-        pClient->disconnect();
-        return false;
-    }
-
     Serial.println("BLE Stream initialized successfully!");
     connected = true;
     return true;

examples/NimBLE_Stream_Echo/NimBLE_Stream_Echo.ino

@@ -3,7 +3,7 @@
  *
  *  A minimal example demonstrating NimBLEStreamServer.
  *  Echoes back any data received from BLE clients.
- *  
+ *
  *  This is the simplest way to use the NimBLE Stream interface,
  *  showing just the essential setup and read/write operations.
  *
@@ -26,11 +26,12 @@ void setup() {
     NimBLEDevice::createServer();
 
     // Initialize stream with default UUIDs, allow writes
-    bleStream.init(NimBLEUUID(uint16_t(0xc0de)),  // Service UUID
-                   NimBLEUUID(uint16_t(0xfeed)),  // Characteristic UUID
-                   true,                           // canWrite
-                   false);                         // secure
-    bleStream.begin();
+    bleStream.init(NimBLEUUID(uint16_t(0xc0de)), // Service UUID
+                   NimBLEUUID(uint16_t(0xfeed)), // Characteristic UUID
+                   1024,                         // txBufSize
+                   1024,                         // rxBufSize
+                   true,                         // canWrite
+                   false);                       // secure
 
     // Start advertising
     NimBLEDevice::getAdvertising()->start();
@@ -39,12 +40,12 @@ void setup() {
 
 void loop() {
     // Echo any received data back to the client
-    if (bleStream.hasSubscriber() && bleStream.available()) {
+    if (bleStream.ready() && bleStream.available()) {
         Serial.print("Echo: ");
         while (bleStream.available()) {
             char c = bleStream.read();
             Serial.write(c);
-            bleStream.write(c);  // Echo back
+            bleStream.write(c); // Echo back
         }
         Serial.println();
     }

examples/NimBLE_Stream_Server/NimBLE_Stream_Server.ino

@@ -3,8 +3,8 @@
  *
  *  Demonstrates using NimBLEStreamServer to create a BLE GATT server
  *  that behaves like a serial port using the Arduino Stream interface.
- *  
- *  This allows you to use familiar methods like print(), println(), 
+ *
+ *  This allows you to use familiar methods like print(), println(),
  *  read(), and available() over BLE, similar to how you would use Serial.
  *
  *  Created: November 2025
@@ -48,8 +48,8 @@ void setup() {
     /** Initialize NimBLE and set the device name */
     NimBLEDevice::init("NimBLE-Stream");
 
-    /** 
-     * Create the BLE server and set callbacks 
+    /**
+     * Create the BLE server and set callbacks
      * Note: The stream will create its own service and characteristic
      */
     NimBLEServer* pServer = NimBLEDevice::createServer();
@@ -58,26 +58,22 @@ void setup() {
     /**
      * Initialize the stream server with:
      * - Service UUID
-     * - Characteristic UUID  
+     * - Characteristic UUID
      * - canWrite: true (allows clients to write data to us)
      * - secure: false (no encryption required - set to true for secure connections)
      */
-    if (!bleStream.init(NimBLEUUID(SERVICE_UUID), 
+    if (!bleStream.init(NimBLEUUID(SERVICE_UUID),
                         NimBLEUUID(CHARACTERISTIC_UUID),
+                        1024,   // txBufSize
+                        1024,   // rxBufSize
                         true,   // canWrite - allow receiving data
                         false)) // secure
     {
         Serial.println("Failed to initialize BLE stream!");
         return;
     }
 
-    /** Start the stream (begins internal buffers and tasks) */
-    if (!bleStream.begin()) {
-        Serial.println("Failed to start BLE stream!");
-        return;
-    }
-
-    /** 
+    /**
      * Create advertising instance and add service UUID
      * This makes the stream service discoverable
      */
@@ -94,32 +90,31 @@ void setup() {
 
 void loop() {
     // Check if a client is subscribed (connected and listening)
-    if (bleStream.hasSubscriber()) {
-        
+    if (bleStream.ready()) {
         // Send a message every 2 seconds using Stream methods
         static unsigned long lastSend = 0;
         if (millis() - lastSend > 2000) {
             lastSend = millis();
-            
+
             // Using familiar Serial-like methods!
             bleStream.print("Hello from BLE Server! Time: ");
             bleStream.println(millis());
-            
+
             // You can also use printf
             bleStream.printf("Free heap: %d bytes\n", ESP.getFreeHeap());
-            
+
             Serial.println("Sent data to client via BLE stream");
         }
 
         // Check if we received any data from the client
         if (bleStream.available()) {
             Serial.print("Received from client: ");
-            
+
             // Read all available data (just like Serial.read())
             while (bleStream.available()) {
                 char c = bleStream.read();
-                Serial.write(c);  // Echo to Serial
-                bleStream.write(c);  // Echo back to BLE client
+                Serial.write(c);    // Echo to Serial
+                bleStream.write(c); // Echo back to BLE client
             }
             Serial.println();
         }

examples/STREAM_EXAMPLES.md

@@ -110,8 +110,6 @@ Both server and client support configuration before calling `begin()`:
 ```cpp
 bleStream.setTxBufSize(2048);       // TX buffer size
 bleStream.setRxBufSize(2048);       // RX buffer size
-bleStream.setTxTaskStackSize(4096); // Task stack size
-bleStream.setTxTaskPriority(1);     // Task priority
 ```
 
 ## Compatibility