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

@@ -30,7 +30,6 @@ void setup() {
                    NimBLEUUID(uint16_t(0xfeed)),  // Characteristic UUID
                    true,                           // canWrite
                    false);                         // secure
-    bleStream.begin();
 
     // Start advertising
     NimBLEDevice::getAdvertising()->start();
@@ -39,7 +38,7 @@ 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();

examples/NimBLE_Stream_Server/NimBLE_Stream_Server.ino

@@ -71,12 +71,6 @@ void setup() {
         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,8 +88,8 @@ 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) {

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