add frame method to Mojo::Transaction::WebSocket

mojolicious · Jan 10, 2016 · 8e54539 · 8e54539
1 parent 065861e
commit 8e54539
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/lib/Mojo/Channel/WebSocket.pm b/lib/Mojo/Channel/WebSocket.pm
@@ -12,10 +12,10 @@ sub read {
   $self->{read} .= $chunk // '';
   while (my $frame = parse_frame \$self->{read}, $tx->max_websocket_size) {
     $tx->finish(1009) and last unless ref $frame;
-    $tx->emit(frame => $frame);
+    $tx->frame($frame);
   }
 
-  $tx->emit('resume');
+  $tx->resume;
 }
 
 

diff --git a/lib/Mojo/Transaction/WebSocket.pm b/lib/Mojo/Transaction/WebSocket.pm
@@ -68,6 +68,8 @@ sub finish {
   return $self;
 }
 
+sub frame { shift->emit(frame => shift) }
+
 sub is_closing { !!shift->{closing} }
 
 sub is_established { !!$_[0]{open} || !!$_[0]{masked} }
@@ -383,6 +385,12 @@ Connection identifier.
 
 Close WebSocket connection gracefully.
 
+=head2 frame
+
+  $ws->frame($frame);
+
+Low-level signal that a WebSocket frame has been received.
+
 =head2 is_closing
 
   my $bool = $ws->is_closing;