package Ġcom . a ero spike . sky hook . listener . key Ċ Ċ import Ġcom . a ero spike . client . Batch Read Ċ import Ġcom . a ero spike . client . listener . Batch List Listener Ċ import Ġcom . a ero spike . client . policy . Batch Policy Ċ import Ġcom . a ero spike . sky hook . command . Request Command Ċ import Ġcom . a ero spike . sky hook . listener . Base Listener Ċ import Ġio . netty . channel . Channel HandlerContext Ċ Ċ class ĠM get Command Listener ( ĊĠĠĠ Ġctx : ĠChannel HandlerContext Ċ ) Ġ: ĠBase Listener ( ctx ), ĠBatch List Listener Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġhandle ( cmd : ĠRequest Command ) Ġ{ ĊĠĠĠĠĠĠĠ Ġrequire ( cmd . arg Count Ġ>= Ġ 2 ) Ġ{ Ġarg ValidationError Msg ( cmd ) Ġ} ĊĊĠĠĠĠĠĠĠ Ġval Ġkeys Ġ= Ġcmd . args . drop ( 1 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġcreate Key ( it ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ ĠBatch Read ( it , Ġtrue ) Ġ} ĊĠĠĠĠĠĠĠ Ġclient . get ( null , Ġthis , ĠBatch Policy ( default Write Policy ), Ġkeys ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun ĠonSuccess ( records : ĠMutable List < Batch Read > ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġif Ġ( records Ġ== Ġnull ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġwrite Null String () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġflush Ctx Transaction Aware () ĊĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġwrite Object List Str ( records . map NotNull Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( it . record Ġ!= Ġnull ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit . record . bins [ a ero Ctx . bin ] ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġelse Ġnull ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ}) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġflush Ctx Transaction Aware () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġclose Ctx ( e ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ