@@ -103,12 +103,14 @@ export const PushRequestPackage = $root.PushRequestPackage = (() => {
103103 * @throws {Error } If the payload is not a reader or valid buffer
104104 * @throws {$protobuf.util.ProtocolError } If required fields are missing
105105 */
106- PushRequest . decode = function decode ( reader , length ) {
106+ PushRequest . decode = function decode ( reader , length , error ) {
107107 if ( ! ( reader instanceof $Reader ) )
108108 reader = $Reader . create ( reader ) ;
109109 let end = length === undefined ? reader . len : reader . pos + length , message = new $root . PushRequestPackage . PushRequest ( ) ;
110110 while ( reader . pos < end ) {
111111 let tag = reader . uint32 ( ) ;
112+ if ( tag === error )
113+ break ;
112114 switch ( tag >>> 3 ) {
113115 case 1 : {
114116 if ( ! ( message . streams && message . streams . length ) )
@@ -349,12 +351,14 @@ export const PushRequestPackage = $root.PushRequestPackage = (() => {
349351 * @throws {Error } If the payload is not a reader or valid buffer
350352 * @throws {$protobuf.util.ProtocolError } If required fields are missing
351353 */
352- StreamAdapter . decode = function decode ( reader , length ) {
354+ StreamAdapter . decode = function decode ( reader , length , error ) {
353355 if ( ! ( reader instanceof $Reader ) )
354356 reader = $Reader . create ( reader ) ;
355357 let end = length === undefined ? reader . len : reader . pos + length , message = new $root . PushRequestPackage . StreamAdapter ( ) ;
356358 while ( reader . pos < end ) {
357359 let tag = reader . uint32 ( ) ;
360+ if ( tag === error )
361+ break ;
358362 switch ( tag >>> 3 ) {
359363 case 1 : {
360364 message . labels = reader . string ( ) ;
@@ -622,12 +626,14 @@ export const PushRequestPackage = $root.PushRequestPackage = (() => {
622626 * @throws {Error } If the payload is not a reader or valid buffer
623627 * @throws {$protobuf.util.ProtocolError } If required fields are missing
624628 */
625- EntryAdapter . decode = function decode ( reader , length ) {
629+ EntryAdapter . decode = function decode ( reader , length , error ) {
626630 if ( ! ( reader instanceof $Reader ) )
627631 reader = $Reader . create ( reader ) ;
628632 let end = length === undefined ? reader . len : reader . pos + length , message = new $root . PushRequestPackage . EntryAdapter ( ) ;
629633 while ( reader . pos < end ) {
630634 let tag = reader . uint32 ( ) ;
635+ if ( tag === error )
636+ break ;
631637 switch ( tag >>> 3 ) {
632638 case 1 : {
633639 message . timestamp = $root . google . protobuf . Timestamp . decode ( reader , reader . uint32 ( ) ) ;
@@ -875,12 +881,14 @@ export const google = $root.google = (() => {
875881 * @throws {Error } If the payload is not a reader or valid buffer
876882 * @throws {$protobuf.util.ProtocolError } If required fields are missing
877883 */
878- Timestamp . decode = function decode ( reader , length ) {
884+ Timestamp . decode = function decode ( reader , length , error ) {
879885 if ( ! ( reader instanceof $Reader ) )
880886 reader = $Reader . create ( reader ) ;
881887 let end = length === undefined ? reader . len : reader . pos + length , message = new $root . google . protobuf . Timestamp ( ) ;
882888 while ( reader . pos < end ) {
883889 let tag = reader . uint32 ( ) ;
890+ if ( tag === error )
891+ break ;
884892 switch ( tag >>> 3 ) {
885893 case 1 : {
886894 message . seconds = reader . int64 ( ) ;
0 commit comments