package Ġorg . sk ellig . test step . processor . tcp . model Ċ Ċ import Ġorg . sk ellig . test step . processing . exception . Test Step Creation Exception Ċ import Ġorg . sk ellig . test step . processing . model . Test Step Execution Type Ċ import Ġorg . sk ellig . test step . processing . model . Validation Details Ċ Ċ open Ġclass ĠTcp Consum able Test Step Ġprotected Ġconstructor ( id : ĠString ?, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġname : ĠString ?, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġtimeout : ĠInt , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġvariables : ĠMap < String , ĠAny ?> ?, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠtestData : ĠAny ?, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġvalidation Details : ĠValidation Details ?, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġconsume From : ĠList < String >, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġrespond To : ĠList < String > ?, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġread BufferSize : ĠInt ) ĊĠĠĠ Ġ: ĠBase Tcp Test Step ( id , Ġname !! , ĠTest Step Execution Type . ASYNC , Ġtimeout , Ġ 0 , Ġ 0 , Ġvariables , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠtestData , Ġvalidation Details , Ġread BufferSize ) Ġ{ ĊĊĊĠĠĠ Ġclass ĠBuilder Ġ: ĠBase Tcp Test Step . Builder < Tcp Consum able Test Step >() Ġ{ ĊĊĠĠĠĠĠĠĠ Ġprivate Ġvar Ġconsume From : ĠList < String >? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġprivate Ġvar Ġrespond To : ĠList < String >? Ġ= Ġnull ĊĊĠĠĠĠĠĠĠ Ġfun Ġconsume From ( consume From : ĠList < String > ?) Ġ= Ġapply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthis . consume From Ġ= Ġconsume From ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġfun Ġrespond To ( respond To : ĠList < String > ?) Ġ= Ġapply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthis . respond To Ġ= Ġrespond To ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġoverride Ġfun Ġbuild (): ĠTcp Consum able Test Step Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġconsume Channels Size Ġ= Ġ( consume From Ġ?: Ġthrow ĠTest Step Creation Exception ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" consume From Ġis Ġmandatory Ġfor ĠTcp Consum able Test Step ")). size ĊĠĠĠĠĠĠĠĠĠĠĠ Ġrespond To ?. let Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( consume Channels Size Ġ!= Ġit . size ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġthrow ĠTest Step Creation Exception (" consume From Ġand Ġrespond To Ġmust Ġhave Ġthe Ġsame Ġsize ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn ĠTcp Consum able Test Step ( id , Ġname !! , Ġtimeout , Ġvariables , ĠtestData , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġvalidation Details , Ġconsume From !! , Ġrespond To , Ġread BufferSize ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }