1
0
mirror of https://github.com/IBM/fp-go.git synced 2025-08-10 22:31:32 +02:00

fix: add some more examples

Signed-off-by: Dr. Carsten Leue <carsten.leue@de.ibm.com>
This commit is contained in:
Dr. Carsten Leue
2023-09-30 23:25:06 +02:00
parent 7400098735
commit 58c60c19e4
5 changed files with 159 additions and 0 deletions

View File

@@ -0,0 +1 @@
Some data

View File

@@ -0,0 +1,3 @@
{
"a": 10
}

View File

@@ -0,0 +1,105 @@
// Copyright (c) 2023 IBM Corp.
// All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package examples
import (
"encoding/json"
"fmt"
"os"
B "github.com/IBM/fp-go/bytes"
F "github.com/IBM/fp-go/function"
IOE "github.com/IBM/fp-go/ioeither"
"github.com/IBM/fp-go/ioeither/file"
J "github.com/IBM/fp-go/json"
T "github.com/IBM/fp-go/tuple"
)
type Sample struct {
Value int `json:"a"`
}
func (s Sample) getValue() int {
return s.Value
}
func Example_io_flow() {
// IOE.IOEither[error, string]
text := F.Pipe2(
"data/file1.txt",
file.ReadFile,
IOE.Map[error](B.ToString),
)
// IOE.IOEither[error, int]
value := F.Pipe3(
"data/file2.json",
file.ReadFile,
IOE.ChainEitherK(J.Unmarshal[Sample]),
IOE.Map[error](Sample.getValue),
)
// IOE.IOEither[error, string]
result := F.Pipe1(
IOE.SequenceT2(text, value),
IOE.Map[error](func(res T.Tuple2[string, int]) string {
return fmt.Sprintf("Text: %s, Number: %d", res.F1, res.F2)
}),
)
fmt.Println(result())
// Output:
// Right[<nil>, string](Text: Some data, Number: 10)
}
func io_flow_idiomatic() error {
// []byte
file1AsBytes, err := os.ReadFile("data/file1.txt")
if err != nil {
return err
}
// string
text := string(file1AsBytes)
// []byte
file2AsBytes, err := os.ReadFile("data/file2.json")
if err != nil {
return err
}
var value Sample
if err := json.Unmarshal(file2AsBytes, &value); err != nil {
return err
}
// string
result := fmt.Sprintf("Text: %s, Number: %d", text, value.Value)
fmt.Println(result)
return nil
}
func Example_io_flow_idiomatic() {
if err := io_flow_idiomatic(); err != nil {
panic(err)
}
// Output:
// Text: Some data, Number: 10
}

View File

@@ -0,0 +1,50 @@
// Copyright (c) 2023 IBM Corp.
// All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package examples
type HKT[T any] struct {
}
// Pointed
func Of[A any](A) HKT[A] { return HKT[A]{} }
// Functor
func Map[A, B any](func(A) B) func(HKT[A]) HKT[B] { return func(HKT[A]) HKT[B] { return HKT[B]{} } }
func MapTo[A, B any](A) func(HKT[A]) HKT[B] { return func(HKT[A]) HKT[B] { return HKT[B]{} } }
// Chain
func Chain[A, B any](func(A) HKT[B]) func(HKT[A]) HKT[B] {
return func(HKT[A]) HKT[B] { return HKT[B]{} }
}
func ChainTo[A, B any](HKT[B]) func(HKT[A]) HKT[B] {
return func(HKT[A]) HKT[B] { return HKT[B]{} }
}
func ChainFirst[A, B any](func(A) HKT[B]) func(HKT[A]) HKT[A] {
return func(HKT[A]) HKT[A] { return HKT[A]{} }
}
// Apply
func Ap[A, B any](HKT[A]) func(HKT[func(A) B]) HKT[B] {
return func(HKT[func(A) B]) HKT[B] { return HKT[B]{} }
}
// Derived
func Flatten[A, B any](HKT[HKT[A]]) HKT[A] {
return HKT[A]{}
}
func Reduce[A, B any](func(B, A) B, B) func(HKT[A]) HKT[B] {
return func(HKT[A]) HKT[B] { return HKT[B]{} }
}