Contents

# frozen_string_literal: true

require 'forwardable'
require 'grpc_kit/session/headers'
require 'grpc_kit/session/stream_status'
require 'grpc_kit/session/recv_buffer'
require 'grpc_kit/session/send_buffer'

module GrpcKit
  module Session
    class Stream
      extend Forwardable

      delegate %i[end_write?] => :@pending_send_data
      delegate %i[end_read?] => :@pending_recv_data
      delegate %i[close close_remote close_local close? close_remote? close_local?] => :@status

      attr_reader :headers, :pending_send_data, :pending_recv_data, :trailer_data, :status
      attr_accessor :inflight, :stream_id

      # @param stream_id [Integer]
      def initialize(stream_id:)
        @stream_id = stream_id
        @end_read_stream = false
        @headers = GrpcKit::Session::Headers.new
        @pending_send_data = GrpcKit::Session::SendBuffer.new
        @pending_recv_data = GrpcKit::Session::RecvBuffer.new

        @inflight = false
        @trailer_data = {}
        @status = GrpcKit::Session::StreamStatus.new
        @draining = false
      end

      def end_write
        @pending_send_data.end_write
      end

      def end_read
        @pending_recv_data.end_read
      end

      # @return [void]
      def drain
        @draining = true
      end

      # @param tarilers [Hash<String,String>]
      # @return [void]
      def write_trailers_data(tarilers)
        @trailer_data = tarilers
      end

      # @param data [String]
      # @param last [Boolean]
      # @return [void]
      def write_send_data(data, last: false)
        @pending_send_data.write(data, last: last)
      end

      # @param last [Boolean]
      # @return [void]
      def read_recv_data(last: false)
        @pending_recv_data.read(last: last)
      end

      # @param name [String]
      # @param value [String]
      # @return [void]
      def add_header(name, value)
        @headers.add(name, value)
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
grpc_kit-0.3.9	lib/grpc_kit/session/stream.rb
grpc_kit-0.3.8	lib/grpc_kit/session/stream.rb
grpc_kit-0.3.7	lib/grpc_kit/session/stream.rb
grpc_kit-0.3.6	lib/grpc_kit/session/stream.rb
grpc_kit-0.3.5	lib/grpc_kit/session/stream.rb
grpc_kit-0.3.4	lib/grpc_kit/session/stream.rb