Net-NATS-Streaming-PB

 view release on metacpan or  search on metacpan

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 2);
    PUSHs(sv_2mortal(newSVpv("subject",0)));
    PUSHs(sv_2mortal(newSVpv("sequence",0)));


SV *
to_hashref(svTHIS)
  SV * svTHIS
  CODE:

PB.xs  view on Meta::CPAN

    }
    THIS->clear_subject();


void
subject(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::Ack * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::Ack") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__Ack *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::Ack");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->subject().c_str(),

PB.xs  view on Meta::CPAN

    THIS->clear_sequence();


void
sequence(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;
    ostringstream ost;

  PPCODE:
    ::Net::NATS::Streaming::PB::Ack * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::Ack") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__Ack *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::Ack");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      ost.str("");

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 1);
    PUSHs(sv_2mortal(newSVpv("clientID",0)));


SV *
to_hashref(svTHIS)
  SV * svTHIS
  CODE:
    ::Net::NATS::Streaming::PB::CloseRequest * THIS;

PB.xs  view on Meta::CPAN

    }
    THIS->clear_clientid();


void
clientID(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::CloseRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::CloseRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__CloseRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::CloseRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->clientid().c_str(),

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 1);
    PUSHs(sv_2mortal(newSVpv("error",0)));


SV *
to_hashref(svTHIS)
  SV * svTHIS
  CODE:
    ::Net::NATS::Streaming::PB::CloseResponse * THIS;

PB.xs  view on Meta::CPAN

    }
    THIS->clear_error();


void
error(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::CloseResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::CloseResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__CloseResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::CloseResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->error().c_str(),

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 2);
    PUSHs(sv_2mortal(newSVpv("clientID",0)));
    PUSHs(sv_2mortal(newSVpv("heartbeatInbox",0)));


SV *
to_hashref(svTHIS)
  SV * svTHIS
  CODE:

PB.xs  view on Meta::CPAN

    }
    THIS->clear_clientid();


void
clientID(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->clientid().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_heartbeatinbox();


void
heartbeatInbox(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->heartbeatinbox().c_str(),

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 7);
    PUSHs(sv_2mortal(newSVpv("pubPrefix",0)));
    PUSHs(sv_2mortal(newSVpv("subRequests",0)));
    PUSHs(sv_2mortal(newSVpv("unsubRequests",0)));
    PUSHs(sv_2mortal(newSVpv("closeRequests",0)));
    PUSHs(sv_2mortal(newSVpv("error",0)));
    PUSHs(sv_2mortal(newSVpv("subCloseRequests",0)));
    PUSHs(sv_2mortal(newSVpv("publicKey",0)));

PB.xs  view on Meta::CPAN

    }
    THIS->clear_pubprefix();


void
pubPrefix(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->pubprefix().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_subrequests();


void
subRequests(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->subrequests().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_unsubrequests();


void
unsubRequests(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->unsubrequests().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_closerequests();


void
closeRequests(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->closerequests().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_error();


void
error(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->error().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_subcloserequests();


void
subCloseRequests(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->subcloserequests().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_publickey();


void
publicKey(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::ConnectResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::ConnectResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__ConnectResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::ConnectResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->publickey().c_str(),

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 7);
    PUSHs(sv_2mortal(newSVpv("sequence",0)));
    PUSHs(sv_2mortal(newSVpv("subject",0)));
    PUSHs(sv_2mortal(newSVpv("reply",0)));
    PUSHs(sv_2mortal(newSVpv("data",0)));
    PUSHs(sv_2mortal(newSVpv("timestamp",0)));
    PUSHs(sv_2mortal(newSVpv("redelivered",0)));
    PUSHs(sv_2mortal(newSVpv("CRC32",0)));

PB.xs  view on Meta::CPAN

    THIS->clear_sequence();


void
sequence(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;
    ostringstream ost;

  PPCODE:
    ::Net::NATS::Streaming::PB::MsgProto * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::MsgProto") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__MsgProto *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::MsgProto");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      ost.str("");

PB.xs  view on Meta::CPAN

    }
    THIS->clear_subject();


void
subject(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::MsgProto * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::MsgProto") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__MsgProto *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::MsgProto");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->subject().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_reply();


void
reply(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::MsgProto * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::MsgProto") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__MsgProto *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::MsgProto");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->reply().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_data();


void
data(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::MsgProto * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::MsgProto") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__MsgProto *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::MsgProto");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->data().c_str(),

PB.xs  view on Meta::CPAN

    THIS->clear_timestamp();


void
timestamp(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;
    ostringstream ost;

  PPCODE:
    ::Net::NATS::Streaming::PB::MsgProto * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::MsgProto") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__MsgProto *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::MsgProto");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      ost.str("");

PB.xs  view on Meta::CPAN

    }
    THIS->clear_redelivered();


void
redelivered(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::MsgProto * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::MsgProto") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__MsgProto *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::MsgProto");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSViv(THIS->redelivered()));

PB.xs  view on Meta::CPAN

    }
    THIS->clear_crc32();


void
CRC32(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::MsgProto * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::MsgProto") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__MsgProto *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::MsgProto");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVuv(THIS->crc32()));

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 2);
    PUSHs(sv_2mortal(newSVpv("guid",0)));
    PUSHs(sv_2mortal(newSVpv("error",0)));


SV *
to_hashref(svTHIS)
  SV * svTHIS
  CODE:

PB.xs  view on Meta::CPAN

    }
    THIS->clear_guid();


void
guid(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::PubAck * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::PubAck") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__PubAck *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::PubAck");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->guid().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_error();


void
error(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::PubAck * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::PubAck") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__PubAck *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::PubAck");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->error().c_str(),

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 6);
    PUSHs(sv_2mortal(newSVpv("clientID",0)));
    PUSHs(sv_2mortal(newSVpv("guid",0)));
    PUSHs(sv_2mortal(newSVpv("subject",0)));
    PUSHs(sv_2mortal(newSVpv("reply",0)));
    PUSHs(sv_2mortal(newSVpv("data",0)));
    PUSHs(sv_2mortal(newSVpv("sha256",0)));

PB.xs  view on Meta::CPAN

    }
    THIS->clear_clientid();


void
clientID(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::PubMsg * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::PubMsg") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__PubMsg *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::PubMsg");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->clientid().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_guid();


void
guid(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::PubMsg * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::PubMsg") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__PubMsg *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::PubMsg");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->guid().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_subject();


void
subject(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::PubMsg * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::PubMsg") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__PubMsg *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::PubMsg");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->subject().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_reply();


void
reply(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::PubMsg * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::PubMsg") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__PubMsg *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::PubMsg");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->reply().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_data();


void
data(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::PubMsg * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::PubMsg") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__PubMsg *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::PubMsg");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->data().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_sha256();


void
sha256(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::PubMsg * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::PubMsg") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__PubMsg *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::PubMsg");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->sha256().c_str(),

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 10);
    PUSHs(sv_2mortal(newSVpv("clientID",0)));
    PUSHs(sv_2mortal(newSVpv("subject",0)));
    PUSHs(sv_2mortal(newSVpv("qGroup",0)));
    PUSHs(sv_2mortal(newSVpv("inbox",0)));
    PUSHs(sv_2mortal(newSVpv("maxInFlight",0)));
    PUSHs(sv_2mortal(newSVpv("ackWaitInSecs",0)));
    PUSHs(sv_2mortal(newSVpv("durableName",0)));
    PUSHs(sv_2mortal(newSVpv("startPosition",0)));

PB.xs  view on Meta::CPAN

    }
    THIS->clear_clientid();


void
clientID(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->clientid().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_subject();


void
subject(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->subject().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_qgroup();


void
qGroup(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->qgroup().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_inbox();


void
inbox(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->inbox().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_maxinflight();


void
maxInFlight(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSViv(THIS->maxinflight()));

PB.xs  view on Meta::CPAN

    }
    THIS->clear_ackwaitinsecs();


void
ackWaitInSecs(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSViv(THIS->ackwaitinsecs()));

PB.xs  view on Meta::CPAN

    }
    THIS->clear_durablename();


void
durableName(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->durablename().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_startposition();


void
startPosition(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSViv(THIS->startposition()));

PB.xs  view on Meta::CPAN

    THIS->clear_startsequence();


void
startSequence(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;
    ostringstream ost;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      ost.str("");

PB.xs  view on Meta::CPAN

    THIS->clear_starttimedelta();


void
startTimeDelta(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;
    ostringstream ost;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      ost.str("");

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 2);
    PUSHs(sv_2mortal(newSVpv("ackInbox",0)));
    PUSHs(sv_2mortal(newSVpv("error",0)));


SV *
to_hashref(svTHIS)
  SV * svTHIS
  CODE:

PB.xs  view on Meta::CPAN

    }
    THIS->clear_ackinbox();


void
ackInbox(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->ackinbox().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_error();


void
error(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::SubscriptionResponse * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::SubscriptionResponse") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__SubscriptionResponse *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::SubscriptionResponse");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->error().c_str(),

PB.xs  view on Meta::CPAN

      RETVAL = 0;
    }

  OUTPUT:
    RETVAL


void
fields(svTHIS)
  SV * svTHIS
  PPCODE:
    (void)svTHIS;
    EXTEND(SP, 4);
    PUSHs(sv_2mortal(newSVpv("clientID",0)));
    PUSHs(sv_2mortal(newSVpv("subject",0)));
    PUSHs(sv_2mortal(newSVpv("inbox",0)));
    PUSHs(sv_2mortal(newSVpv("durableName",0)));


SV *
to_hashref(svTHIS)

PB.xs  view on Meta::CPAN

    }
    THIS->clear_clientid();


void
clientID(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::UnsubscribeRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::UnsubscribeRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__UnsubscribeRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::UnsubscribeRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->clientid().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_subject();


void
subject(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::UnsubscribeRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::UnsubscribeRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__UnsubscribeRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::UnsubscribeRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->subject().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_inbox();


void
inbox(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::UnsubscribeRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::UnsubscribeRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__UnsubscribeRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::UnsubscribeRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->inbox().c_str(),

PB.xs  view on Meta::CPAN

    }
    THIS->clear_durablename();


void
durableName(svTHIS)
  SV * svTHIS;
PREINIT:
    SV * sv;

  PPCODE:
    ::Net::NATS::Streaming::PB::UnsubscribeRequest * THIS;
    if ( sv_derived_from(svTHIS, "Net::NATS::Streaming::PB::UnsubscribeRequest") ) {
      IV tmp = SvIV((SV *)SvRV(svTHIS));
      THIS = INT2PTR(__Net__NATS__Streaming__PB__UnsubscribeRequest *, tmp);
    } else {
      croak("THIS is not of type Net::NATS::Streaming::PB::UnsubscribeRequest");
    }
    if ( THIS != NULL ) {
      EXTEND(SP,1);
      sv = sv_2mortal(newSVpv(THIS->durablename().c_str(),