simple EM::P::LineProtocol

lib/em/protocols.rb

@@ -5,7 +5,7 @@ module EventMachine
   # - Memcache
   # - SmtpClient and SmtpServer
   # - SASLauth and SASLauthclient
-  # - LineAndTextProtocol and LineText2
+  # - LineProtocol, LineAndTextProtocol and LineText2
   # - HeaderAndContentProtocol
   # - Postgres3
   # - ObjectProtocol

lib/em/protocols/line_protocol.rb

@@ -0,0 +1,28 @@
+module EventMachine
+  module Protocols
+    # LineProtocol will parse out newline terminated strings from a receive_data stream
+    #
+    #  module Server
+    #    include EM::P::LineProtocol
+    #
+    #    def receive_line(line)
+    #      send_data("you said: #{line}")
+    #    end
+    #  end
+    #
+    module LineProtocol
+      def receive_data data # :nodoc:
+        (@buf ||= '') << data
+
+        while line = @buf.slice!(/(.*)\r?\n/)
+          receive_line(line)
+        end
+      end
+
+      # Invoked with lines received over the network
+      def receive_line(line)
+        # stub
+      end
+    end
+  end
+end