@@ -202,6 +202,8 @@ check_write_permitted(Resource, User) ->
202
202
check_read_permitted (Resource , User , Context ) ->
203
203
check_resource_access (User , Resource , read , Context ).
204
204
205
+ -spec check_super_stream_management_permitted (binary (), binary (), [binary ()], binary ()) ->
206
+ ok | error .
205
207
check_super_stream_management_permitted (VirtualHost , SuperStream , Partitions , User ) ->
206
208
Exchange = e (VirtualHost , SuperStream ),
207
209
maybe
@@ -214,12 +216,9 @@ check_super_stream_management_permitted(VirtualHost, SuperStream, Partitions, Us
214
216
% % binding from exchange
215
217
ok ?= check_read_permitted (Exchange , User , #{}),
216
218
% % binding to streams
217
- ok ?= check_streams_permissions (fun check_write_permitted /2 ,
218
- VirtualHost , Partitions ,
219
- User )
220
- else
221
- _ ->
222
- error
219
+ check_streams_permissions (fun check_write_permitted /2 ,
220
+ VirtualHost , Partitions ,
221
+ User )
223
222
end .
224
223
225
224
check_streams_permissions (Fun , VirtualHost , List , User ) ->
0 commit comments