(blockId string, termWidth int)
| 1572 | } |
| 1573 | |
| 1574 | func writeSessionSeparatorToTerminal(blockId string, termWidth int) { |
| 1575 | if blockId == "" { |
| 1576 | return |
| 1577 | } |
| 1578 | ctx, cancelFn := context.WithTimeout(context.Background(), DefaultTimeout) |
| 1579 | defer cancelFn() |
| 1580 | if isFileEmpty(ctx, blockId) { |
| 1581 | return |
| 1582 | } |
| 1583 | separatorLine := "\r\n" |
| 1584 | err := doWFSAppend(ctx, waveobj.MakeORef(waveobj.OType_Block, blockId), JobOutputFileName, []byte(separatorLine)) |
| 1585 | if err != nil { |
| 1586 | log.Printf("error writing session separator to terminal (blockid=%s): %v", blockId, err) |
| 1587 | } |
| 1588 | } |
| 1589 | |
| 1590 | // msg should not have a terminating newline |
| 1591 | func writeMutedMessageToTerminal(blockId string, msg string) { |
no test coverage detected