5
5
6
6
module Kuby
7
7
class CLIBase
8
- extend T ::Sig
8
+ # extend T::Sig
9
9
10
- BeforeCallback = T . type_alias { T . proc . params ( cmd : T ::Array [ String ] ) . void }
11
- AfterCallback = T . type_alias do
12
- T . proc . params ( cmd : T ::Array [ String ] , last_status : T . nilable ( Process ::Status ) ) . void
13
- end
10
+ # BeforeCallback = T.type_alias { T.proc.params(cmd: T::Array[String]).void }
11
+ # AfterCallback = T.type_alias do
12
+ # T.proc.params(cmd: T::Array[String], last_status: T.nilable(Process::Status)).void
13
+ # end
14
14
15
- T ::Sig ::WithoutRuntime . sig { returns ( T . nilable ( Process ::Status ) ) }
15
+ # T::Sig::WithoutRuntime.sig { returns(T.nilable(Process::Status)) }
16
16
def last_status
17
17
Thread . current [ status_key ]
18
18
end
19
19
20
- T ::Sig ::WithoutRuntime . sig { params ( block : BeforeCallback ) . void }
20
+ # T::Sig::WithoutRuntime.sig { params(block: BeforeCallback).void }
21
21
def before_execute ( &block )
22
- @before_execute = T . let ( @before_execute , T . nilable ( T ::Array [ BeforeCallback ] ) )
22
+ # @before_execute = T.let(@before_execute, T.nilable(T::Array[BeforeCallback]))
23
23
@before_execute ||= [ ]
24
24
@before_execute << block
25
25
end
26
26
27
- T ::Sig ::WithoutRuntime . sig { params ( block : AfterCallback ) . void }
27
+ # T::Sig::WithoutRuntime.sig { params(block: AfterCallback).void }
28
28
def after_execute ( &block )
29
- @after_execute = T . let ( @after_execute , T . nilable ( T ::Array [ AfterCallback ] ) )
29
+ # @after_execute = T.let(@after_execute, T.nilable(T::Array[AfterCallback]))
30
30
@after_execute ||= [ ]
31
31
@after_execute << block
32
32
end
33
33
34
- T ::Sig ::WithoutRuntime . sig {
35
- params (
36
- out : T . any ( IO , StringIO ) ,
37
- err : T . any ( IO , StringIO ) ,
38
- block : T . proc . void
39
- ) . void
40
- }
34
+ # T::Sig::WithoutRuntime.sig {
35
+ # params(
36
+ # out: T.any(IO, StringIO),
37
+ # err: T.any(IO, StringIO),
38
+ # block: T.proc.void
39
+ # ).void
40
+ # }
41
41
def with_pipes ( out = STDOUT , err = STDERR , &block )
42
42
previous_stdout = self . stdout
43
43
previous_stderr = self . stderr
@@ -49,34 +49,34 @@ def with_pipes(out = STDOUT, err = STDERR, &block)
49
49
self . stderr = previous_stderr
50
50
end
51
51
52
- T ::Sig ::WithoutRuntime . sig { returns ( T . nilable ( T . any ( IO , StringIO ) ) ) }
52
+ # T::Sig::WithoutRuntime.sig { returns(T.nilable(T.any(IO, StringIO))) }
53
53
def stdout
54
54
Thread . current [ stdout_key ] || STDOUT
55
55
end
56
56
57
- T ::Sig ::WithoutRuntime . sig { params ( new_stdout : T . nilable ( T . any ( IO , StringIO ) ) ) . void }
57
+ # T::Sig::WithoutRuntime.sig { params(new_stdout: T.nilable(T.any(IO, StringIO))).void }
58
58
def stdout = ( new_stdout )
59
59
Thread . current [ stdout_key ] = new_stdout
60
60
end
61
61
62
- T ::Sig ::WithoutRuntime . sig { returns ( T . nilable ( T . any ( IO , StringIO ) ) ) }
62
+ # T::Sig::WithoutRuntime.sig { returns(T.nilable(T.any(IO, StringIO))) }
63
63
def stderr
64
64
Thread . current [ stderr_key ] || STDERR
65
65
end
66
66
67
- T ::Sig ::WithoutRuntime . sig { params ( new_stderr : T . nilable ( T . any ( IO , StringIO ) ) ) . void }
67
+ # T::Sig::WithoutRuntime.sig { params(new_stderr: T.nilable(T.any(IO, StringIO))).void }
68
68
def stderr = ( new_stderr )
69
69
Thread . current [ stderr_key ] = new_stderr
70
70
end
71
71
72
72
private
73
73
74
- T ::Sig ::WithoutRuntime . sig {
75
- params (
76
- cmd : T ::Array [ String ] ,
77
- block : T . proc . params ( stdin : IO ) . void
78
- ) . void
79
- }
74
+ # T::Sig::WithoutRuntime.sig {
75
+ # params(
76
+ # cmd: T::Array[String],
77
+ # block: T.proc.params(stdin: IO).void
78
+ # ).void
79
+ # }
80
80
def open3_w ( cmd , &block )
81
81
run_before_callbacks ( cmd )
82
82
cmd_s = cmd . join ( ' ' )
@@ -99,20 +99,20 @@ def open3_w(cmd, &block)
99
99
yield ( p_stdin )
100
100
101
101
p_stdin . close
102
- self . last_status = T . cast ( wait_thread . value , Process :: Status )
102
+ self . last_status = wait_thread . value
103
103
run_after_callbacks ( cmd )
104
104
wait_thread . join
105
105
end
106
106
end
107
107
108
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . void }
108
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).void }
109
109
def execc ( cmd )
110
110
run_before_callbacks ( cmd )
111
111
cmd_s = cmd . join ( ' ' )
112
112
exec ( cmd_s )
113
113
end
114
114
115
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . void }
115
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).void }
116
116
def systemm ( cmd )
117
117
if stdout == STDOUT && stderr == STDERR
118
118
systemm_default ( cmd )
@@ -121,7 +121,7 @@ def systemm(cmd)
121
121
end
122
122
end
123
123
124
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . void }
124
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).void }
125
125
def systemm_default ( cmd )
126
126
run_before_callbacks ( cmd )
127
127
cmd_s = cmd . join ( ' ' )
@@ -131,7 +131,7 @@ def systemm_default(cmd)
131
131
end
132
132
end
133
133
134
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . void }
134
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).void }
135
135
def systemm_open3 ( cmd )
136
136
run_before_callbacks ( cmd )
137
137
cmd_s = cmd . join ( ' ' )
@@ -152,14 +152,14 @@ def systemm_open3(cmd)
152
152
end
153
153
154
154
p_stdin . close
155
- self . last_status = T . cast ( wait_thread . value , Process :: Status )
155
+ self . last_status = wait_thread . value
156
156
run_after_callbacks ( cmd )
157
157
wait_thread . join
158
158
end
159
159
end
160
160
161
161
162
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . returns ( String ) }
162
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).returns(String) }
163
163
def backticks ( cmd )
164
164
if stdout == STDOUT && stderr == STDERR
165
165
backticks_default ( cmd )
@@ -168,7 +168,7 @@ def backticks(cmd)
168
168
end
169
169
end
170
170
171
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . returns ( String ) }
171
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).returns(String) }
172
172
def backticks_default ( cmd )
173
173
run_before_callbacks ( cmd )
174
174
cmd_s = cmd . join ( ' ' )
@@ -178,7 +178,7 @@ def backticks_default(cmd)
178
178
end
179
179
end
180
180
181
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . returns ( String ) }
181
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).returns(String) }
182
182
def backticks_open3 ( cmd )
183
183
run_before_callbacks ( cmd )
184
184
cmd_s = cmd . join ( ' ' )
@@ -200,40 +200,40 @@ def backticks_open3(cmd)
200
200
end
201
201
202
202
p_stdin . close
203
- self . last_status = T . cast ( wait_thread . value , Process :: Status )
203
+ self . last_status = wait_thread . value
204
204
run_after_callbacks ( cmd )
205
205
wait_thread . join
206
206
end
207
207
208
208
result . string
209
209
end
210
210
211
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . void }
211
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).void }
212
212
def run_before_callbacks ( cmd )
213
213
( @before_execute || [ ] ) . each { |cb | cb . call ( cmd ) }
214
214
end
215
215
216
- T ::Sig ::WithoutRuntime . sig { params ( cmd : T ::Array [ String ] ) . void }
216
+ # T::Sig::WithoutRuntime.sig { params(cmd: T::Array[String]).void }
217
217
def run_after_callbacks ( cmd )
218
218
( @after_execute || [ ] ) . each { |cb | cb . call ( cmd , last_status ) }
219
219
end
220
220
221
- T ::Sig ::WithoutRuntime . sig { params ( status : Process ::Status ) . void }
221
+ # T::Sig::WithoutRuntime.sig { params(status: Process::Status).void }
222
222
def last_status = ( status )
223
223
Thread . current [ status_key ] = status
224
224
end
225
225
226
- T ::Sig ::WithoutRuntime . sig { returns ( Symbol ) }
226
+ # T::Sig::WithoutRuntime.sig { returns(Symbol) }
227
227
def status_key
228
228
raise NotImplementedError , "#{ __method__ } must be defined in derived classes"
229
229
end
230
230
231
- T ::Sig ::WithoutRuntime . sig { returns ( Symbol ) }
231
+ # T::Sig::WithoutRuntime.sig { returns(Symbol) }
232
232
def stdout_key
233
233
raise NotImplementedError , "#{ __method__ } must be defined in derived classes"
234
234
end
235
235
236
- T ::Sig ::WithoutRuntime . sig { returns ( Symbol ) }
236
+ # T::Sig::WithoutRuntime.sig { returns(Symbol) }
237
237
def stderr_key
238
238
raise NotImplementedError , "#{ __method__ } must be defined in derived classes"
239
239
end
0 commit comments