@@ -481,7 +481,7 @@ export function deleteStreamEntry(key: string, entries: string[], onSuccessActio
481
481
// Asynchronous thunk action
482
482
export function fetchConsumerGroups (
483
483
resetData ?: boolean ,
484
- onSuccess ?: ( data : GetStreamEntriesResponse ) => void ,
484
+ onSuccess ?: ( ) => void ,
485
485
onFailed ?: ( ) => void ,
486
486
) {
487
487
return async ( dispatch : AppDispatch , stateInit : ( ) => RootState ) => {
@@ -501,7 +501,7 @@ export function fetchConsumerGroups(
501
501
502
502
if ( isStatusSuccessful ( status ) ) {
503
503
dispatch ( loadConsumerGroupsSuccess ( data ) )
504
- onSuccess ?.( data )
504
+ onSuccess ?.( )
505
505
}
506
506
} catch ( _err ) {
507
507
if ( ! axios . isCancel ( _err ) ) {
@@ -518,7 +518,7 @@ export function fetchConsumerGroups(
518
518
// Asynchronous thunk action
519
519
export function fetchConsumers (
520
520
resetData ?: boolean ,
521
- onSuccess ?: ( data : GetStreamEntriesResponse ) => void ,
521
+ onSuccess ?: ( ) => void ,
522
522
onFailed ?: ( ) => void ,
523
523
) {
524
524
return async ( dispatch : AppDispatch , stateInit : ( ) => RootState ) => {
@@ -556,7 +556,7 @@ export function fetchConsumers(
556
556
// Asynchronous thunk action
557
557
export function fetchConsumerMessages (
558
558
resetData ?: boolean ,
559
- onSuccess ?: ( data : PendingEntryDto [ ] ) => void ,
559
+ onSuccess ?: ( ) => void ,
560
560
onFailed ?: ( ) => void ,
561
561
) {
562
562
return async ( dispatch : AppDispatch , stateInit : ( ) => RootState ) => {
@@ -577,7 +577,7 @@ export function fetchConsumerMessages(
577
577
)
578
578
if ( isStatusSuccessful ( status ) ) {
579
579
dispatch ( loadConsumerMessagesSuccess ( data ) )
580
- onSuccess ?.( data )
580
+ onSuccess ?.( )
581
581
}
582
582
} catch ( _err ) {
583
583
if ( ! axios . isCancel ( _err ) ) {
0 commit comments