Refactoring Your Code with Java 8: Functional Programming to the Rescue

This session shows how you can refactor your traditional object-oriented Java code by using functional programming features and APIs from Java 8, following several recipes, and refactoring legacy code to make it more readable and flexible. Find out:

- How to separate concerns with lambda expressions
- How to handle requirement changes with first-class functions
- How to make several traditional OO design patterns more concise with lambda expressions
The session balances theoretical concepts and practical applications. Attendees will leave with concrete knowledge about refactoring their traditional object-oriented Java code to make the best use of functional programming features and new Java 8 APIs.

Transcript

1. Refactoring Your Code with Java 8 FP to the Rescue Eder Ignatowicz @ederign Sr. Software Engineer JBoss by Red Hat
3. Design Patterns + Java + Functional Programming <3
4. Refactoring Loops to Collection Pipelines
5. public class Client { private String name; private String email; private Company company; public Client( String name, String email, Company company ) { this.name = name; this.email = email; this.company = company; } public Client( String name ) { this.name = name; } public Client( String name, String email ) { this.name = name; this.email = email; } … }
6. public class ClientRepositoryTest { private ClientRepository repo; @Before public void setup() { Company rh = new Company( "RedHat" ); Client full1 = new Client( "Full1", "full1@redhat.com", rh ); Client full2 = new Client( "Full2", "full2@redhat.com", rh ); Client noCompany = new Client( "noCompany", "noCompany@ederign.me" ); Client onlyName = new Client( "onlyName" ); repo = new ClientRepository( Arrays.asList( full1, noCompany, full2, onlyName ) ); } @Test public void getClientEmailsWithCompanyTest() { List<String> clientMails = repo.getClientMails(); assertEquals( 2, clientMails.size() ); assertTrue( clientMails.contains( "full1@redhat.com" ) ); assertTrue( clientMails.contains( "full2@redhat.com" ) ); assertTrue( !clientMails.contains( "noCompany@ederign.me" ) ); } }
7. public List<String> getClientMails() { ArrayList<String> emails = new ArrayList<>(); for ( Client client : clients ) { if ( client.getCompany() != null ) { String email = client.getEmail(); if ( email != null ){ emails.add( email ); } } } return emails; }
8. public List<String> getClientMails() { ArrayList<String> emails = new ArrayList<>(); List<Client> pipeline = clients; for ( Client client : pipeline ) { if ( client.getCompany() != null ) { String email = client.getEmail(); if ( email != null ){ emails.add( email ); } } } return emails; } } Extract Variable
9. public List<String> getClientMails() { ArrayList<String> emails = new ArrayList<>(); List<Client> pipeline = clients .stream() .filter( c -> c.getCompany() != null ) .collect( Collectors.toList() ); for ( Client client : pipeline ) { if ( client.getCompany() != null ) { String email = client.getEmail(); if ( email != null ) { emails.add( email ); } } } return emails; } } Filter Operation
10. Map Operation public List<String> getClientMails() { ArrayList<String> emails = new ArrayList<>(); List<String> pipeline = clients .stream() .filter( c -> c.getCompany() != null ) .map( c -> c.getEmail() ) .collect( Collectors.toList() ); for ( String mail : pipeline ) { String email = client.getEmail(); if ( email != null ) { emails.add( mail ); } } return emails; }
11. Filter Operation public List<String> getClientMails() { ArrayList<String> emails = new ArrayList<>(); List<String> pipeline = clients .stream() .filter( c -> c.getCompany() != null ) .map( c -> c.getEmail() ) .filter( m -> m != null ) .collect( Collectors.toList() ); for ( String mail : pipeline ) { if ( mail != null ) { emails.add( mail ); } } return emails; }
12. Pipeline public List<String> getClientMails() { ArrayList<String> emails = new ArrayList<>(); return clients .stream() .filter( c -> c.getCompany() != null ) .map( c -> c.getEmail() ) .filter( m -> m != null ) .collect( Collectors.toList() ); for ( String mail : pipeline ) { if ( mail != null ) { emails.add( mail ); } } return emails; }
13. public List<String> getClientMails() { return clients .stream() .filter( c -> c.getCompany() != null ) .map( c -> c.getEmail() ) .filter( m -> m != null ) .collect( Collectors.toList() ); }
14. Strategy “Define a family of algorithms, encapsulate each one, and make them interchangeable. Strategy lets the algorithm vary independently from the clients that use it.” GAMMA, Erich et al.
15. public class ShoppingCartTest { ShoppingCart cart; @Before public void setup() { Item item1 = new Item( 10 ); Item item2 = new Item( 20 ); cart = new ShoppingCart( Arrays.asList( item1, item2 ) ); } @Test public void totalTest() { cart.pay( ShoppingCart.PaymentMethod.CREDIT ) ); } }
16. public class ShoppingCart { private List<Item> items; public ShoppingCart( List<Item> items ) { this.items = items; } public void pay( PaymentMethod method ) { int total = cartTotal(); if ( method == PaymentMethod.CREDIT ) { System.out.println( “Pay with credit “ + total); } else if ( method == PaymentMethod.MONEY ) { System.out.println( “Pay with money “ + total ); } } private int cartTotal() { return items .stream() .mapToInt( Item::getValue ) .sum(); } … }
17. public class ShoppingCart { private List<Item> items; public ShoppingCart( List<Item> items ) { this.items = items; } public void pay( PaymentMethod method ) { int total = cartTotal(); if ( method == PaymentMethod.CREDIT ) { System.out.println( “Pay with credit “ + total ); } else if ( method == PaymentMethod.MONEY ) { System.out.println( “Pay with money “ + total ); } } private int cartTotal() { return items .stream() .mapToInt( Item::getValue ) .sum(); } … }
18. public interface Payment { public void pay(int amount); } public class CreditCard implements Payment { @Override public void pay( int amount ) { System.out.println( "Pay with Credit: “+ amount); } } public class Money implements Payment { @Override public void pay( int amount ) { System.out.println( "Pay with Money: “+ amount); }
19. public class ShoppingCart { … public void pay( Payment method ) { int total = cartTotal(); method.pay( total ); } private int cartTotal() { return items .stream() .mapToInt( Item::getValue ) .sum(); } } Strategy
20. public interface Payment { public void pay(int amount); } public class CreditCard implements Payment { @Override public void pay( int amount ) { System.out.println( "make credit payment logic" ); } } public class Money implements Payment { @Override public void pay( int amount ) { System.out.println( "make money payment logic" ); } } public class DebitCard implements Payment { @Override public void pay( int amount ) { System.out.println( "make debit payment logic" ); } } public void totalTest() { assertEquals( 30, cart.pay( new CreditCard() ) ); assertEquals( 30, cart.pay( new Money() ) ); assertEquals( 30, cart.pay( new DebitCard() ) ); } }
22. public class ShoppingCart { … public void pay( Consumer<Integer> method ) { int total = cartTotal(); method.accept( total ); } … } public void pay( Payment method ) { int total = cartTotal(); method.pay( total ); }
23. public class ShoppingCart { … public void pay( Consumer<Integer> method ) { int total = cartTotal(); method.accept( total ); } … } public void totalTest() { cart.pay( amount -> System.out.println( "Pay with Credit: " + amount ) ); cart.pay( amount -> System.out.println( "Pay with Money: " + amount ) ); cart.pay( amount -> System.out.println( "Pay with Debit: " + amount ) ); }
24. public class PaymentTypes { public static void money( int amount ) { System.out.println( "Pay with Money: " + amount ); } public static void debit( int amount ) { System.out.println( "Pay with Debit: " + amount ); } public static void credit( int amount ) { System.out.println( "Pay with Credit: " + amount ); } } public void totalTest() { cart.pay( PaymentTypes::credit ); cart.pay( PaymentTypes::debit ); cart.pay( PaymentTypes::money ); }
25. public class ShoppingCart { … public void pay( Consumer<Integer> method ) { int total = cartTotal(); method.accept( total ); } private int cartTotal() { return items .stream() .mapToInt( Item::getValue ) .sum(); } } Strategy
26. Decorator “Attach additional responsibilities to an object dynamically. Decorators provide a flexible alternative to subclassing for extending functionality..” GAMMA, Erich et al.
27. new BufferedReader(new FileReader(new File("some.file")));
28. public class Item { private int price; public Item( int price ) { this.price = price; } public int getPrice() { return price; } } Extras Shipping Taxes Packing
29. public interface Item { int getPrice(); } public class Book implements Item { private int price; public Book( int price ) { this.price = price; } @Override public int getPrice() { return price; } }
30. public abstract class ItemExtras implements Item { private Item item; public ItemExtras( Item item ) { this.item = item; } @Override public int getPrice() { return item.getPrice(); } }
31. public class InternationalDelivery extends ItemExtras { public InternationalDelivery( Item item ) { super( item ); } @Override public int getPrice() { return 5 + super.getPrice(); } }
32. public class GiftPacking extends ItemExtras { public GiftPacking( Item item ) { super( item ); } @Override public int getPrice() { return 15 + super.getPrice(); } }
33. public static void main( String[] args ) { Item book = new Book( 10 ); book.getPrice(); //10 Item international = new InternationalDelivery( book ); international.getPrice(); //15 }
34. public static void main( String[] args ) { Item book = new Book( 10 ); book.getPrice(); //10 Item internationalGift = new GiftPacking( new InternationalDelivery( book ) ); internationalGift.getPrice(); //30 }
35. public static void main( String[] args ) { Item book = new Book( 10 ); book.getPrice(); //10 Item internationalGiftWithTaxes = new InternacionalTaxes( new GiftPacking( new InternationalDelivery( book ); internationalGiftWithTaxes.getPrice(); //80 } }
36. public static void main( String[] args ) { Item book = new Item( 10 ); book.getPrice(); //10 Function<Integer, Integer> giftPacking = value -> value + 15; giftPacking.apply( book.getPrice() ); //25 }
37. public static void main( String[] args ) { Item book = new Item( 10 ); book.getPrice(); //10 Function<Integer, Integer> giftPacking = value -> value + 15; giftPacking.apply( book.getPrice() ); //25 Function<Integer, Integer> intTaxes = value -> value + 50; intTaxes.apply( book.getPrice() ); //60 }
38. public static void main( String[] args ) { Item book = new Item( 10 ); book.getPrice(); //10 Function<Integer, Integer> giftPacking = value -> value + 15; giftPacking.apply( book.getPrice() ); //25 Function<Integer, Integer> intTaxes = value -> value + 50; intTaxes.apply( book.getPrice() ); //60 giftPacking.andThen( intTaxes ).apply( book.getPrice() ); //75 }
39. public class Item { private int price; private Function<Integer, Integer>[] itemExtras = new Function[]{}; public Item( int price ) { this.price = price; } public Item( int price, Function<Integer, Integer>... itemExtras) { this.price = price; this.itemExtras = itemExtras; } public int getPrice() { int priceWithExtras = price; for ( Function<Integer, Integer> itemExtra : itemExtras ) { priceWithExtras = itemExtra.apply( priceWithExtras ); } return priceWithExtras; } public void setItemExtras( Function<Integer, Integer>... itemExtras ) { this.itemExtras = itemExtras; } }
40. public static void main( String[] args ) { Item book = new Item( 10 ); Function<Integer, Integer> giftPacking = value -> value + 15; Function<Integer, Integer> intTaxes = value -> value + 50; book.setItemExtras( giftPacking, intTaxes ); book.getPrice(); //75 }
41. public static void main( String[] args ) { Item book = new Item( 10 ); Function<Integer, Integer> giftPacking = value -> value + 15; Function<Integer, Integer> intTaxes = value -> value + 50; book.setItemExtras( giftPacking, intTaxes ); book.getPrice(); //75 }
42. public class Packing { public static Integer giftPacking( Integer value ) { return value + 15; } //other packing options here } public class Taxes { public static Integer internacional( Integer value ) { return value + 50; } //other taxes here }
43. public static void main( String[] args ) { Item book = new Item( 10, Packing::giftPacking, Taxes::internacional ); book.getPrice(); //75 }
44. public class Item { private int price; private Function<Integer, Integer>[] itemExtras = new Function[]{}; public Item( int price ) { this.price = price; } public Item( int price, Function<Integer, Integer>... itemExtras) { this.price = price; this.itemExtras = itemExtras; } public int getPrice() { int priceWithExtras = price; for ( Function<Integer, Integer> itemExtra : itemExtras ) { priceWithExtras = itemExtra.apply( priceWithExtras ); } return priceWithExtras; } public void setItemExtras( Function<Integer, Integer>... itemExtras ) { this.itemExtras = itemExtras; } }
45. public class Item { private int price; private Function<Integer, Integer>[] itemExtras = new Function[]{}; public Item( int price ) { this.price = price; } public Item( int price, Function<Integer, Integer>... itemExtras ) { this.price = price; this.itemExtras = itemExtras; } public int getPrice() { Function<Integer, Integer> extras = Stream.of( itemExtras ) .reduce( Function.identity(), Function::andThen ); return extras.apply( price ); } public void setItemExtras( Function<Integer, Integer>... itemExtras ) { this.itemExtras = itemExtras; } }
46. Template “Define the skeleton of an algorithm in an operation, deferring some steps to client subclasses. Template Method lets subclasses redefine certain steps of an algorithm without changing the algorithm's structure.” GAMMA, Erich et al.
47. public abstract class Banking { public void processOperation( Operation op ) { preProcessing( op ); process( op ); postProcessing( op ); } protected abstract void postProcessing( Operation op ); protected abstract void preProcessing( Operation op ); private void process( Operation op ) { //logic op.process( op ); } }
48. public class VIPBanking extends Banking { @Override protected void preProcessing( Operation op ) { //pre processing vip logic } @Override protected void postProcessing( Operation op ) { //post processing vip logic } } public class OnlineBanking extends Banking { @Override protected void preProcessing( Operation op ) { //pre processing online logic } @Override protected void postProcessing( Operation op ) { //post processing online logic } }
49. public class Banking { public void processOperation( Operation op ) { process( op ); } public void processOperation( Operation op, Consumer<Operation> preProcessing, Consumer<Operation> postProcessing ) { preProcessing.accept( op ); process( op ); postProcessing.accept( op ); } private void process( Operation op ) { //logic op.process( op ); } }
50. Execute Around
51. public static void main( String[] args ) throws IOException { BufferedReader br = new BufferedReader( new FileReader( "dora.txt" ) ); try { br.readLine(); } finally { br.close(); } }
52. Init code Task Cleanup
53. public static void main( String[] args ) throws IOException { BufferedReader br = new BufferedReader( new FileReader( "dora.txt" ) ); try { br.readLine(); } finally { br.close(); } }
54. try ( BufferedReader br = new BufferedReader( new FileReader( "dora.txt" )){ br.readLine(); }
55. @Override public ServerTemplate store( final ServerTemplate serverTemplate, final List<ServerTemplateKey> keys){ final Path path = buildPath( serverTemplate.getId() ); try { ioService.startBatch(path.getFileSystem()); ioService.write(path, serverTemplate); ioService.write(path, keys); } finally { ioService.endBatch(); } return serverTemplate; }
56. public void store( final ServerTemplate serverTemplate, final List<ServerTemplateKeys> keys ) try { ioService.startBatch( path.getFileSystem() ); ioService.write( path, serverTemplate ); ioService.write( path, keys ); } finally { ioService.endBatch(); } }
57. public class IOService { … public void processInBatch( Path path, Consumer<Path> batchOp ) { try { startBatch( path.getFileSystem() ); batchOp.accept( path ); } finally { endBatch(); } } }
58. public void store( final ServerTemplate serverTemplate, final List<ServerTemplateKeys> keys){ try { ioService.startBatch( path.getFileSystem() ); ioService.write( path, serverTemplate ); ioService.write( path, keys ); } finally { ioService.endBatch(); } }
59. public void store( final ServerTemplate serverTemplate, final List<ServerTemplateKeys> keys) ioService.processInBatch( path, ( path ) -> { ioService.write( path, serverTemplate ); ioService.write( path, keys ); } ); }
60. public void delete( final ServerTemplate serverTemplate, final List<ServerTemplateKeys> keys ) { ioService.processInBatch( path, ( path ) -> { ioService.delete( path, serverTemplate ); ioService.delete( path, keys ); } ); }
61. Chain of Responsibilities “Avoid coupling the sender of a request to its receiver by giving more than one object a chance to handle the request. Chain the receiving objects and pass the request along the chain until an object handles it.” GAMMA, Erich et al.
62. Client Handler 1 Request Handler 2 Request … Handler N Chain of Responsibilities
63. Client Payment Processor 1 Payment Payment … Payment Processor 2 Payment Processor n
64. public static void main( String[] args ) { PaymentProcessor paymentProcessor = getPaymentProcessor(); paymentProcessor.process( new Payment( 10 ) ); } private static PaymentProcessor getPaymentProcessor() { PaymentProcessor g = new PaymentProcessorA(); g.setNext( new PaymentProcessorB() ); g.setNext( new PaymentProcessorC() ); return g; }
65. public abstract class PaymentProcessor { private PaymentProcessor next; public void setNext( PaymentProcessor processors ) { if ( next == null ) { next = processors; } else { next.setNext( processors ); } } public Payment process( Payment p ) { handle( p ); if ( next != null ) { return next.process( p ); } else { return p; } } protected abstract void handle( Payment p ); }
66. public class PaymentProcessorA extends PaymentProcessor { @Override protected void handle( Payment p ) { System.out.println( "PaymentProcessorA for payment: " + p.getAmount() ); } } public class PaymentProcessorB extends PaymentProcessor { @Override protected void handle( Payment p ) { System.out.println( "PaymentProcessorB for payment: " + p.getAmount() ); } }
67. public static void main( String[] args ) { PaymentProcessor paymentProcessor = getPaymentProcessor(); paymentProcessor.process( new Payment( 10 ) ); //PaymentProcessorA for payment: 10 //PaymentProcessorB for payment: 10 //PaymentProcessorC for payment: 10 } private static PaymentProcessor getPaymentProcessor() { PaymentProcessor g = new PaymentProcessorA(); g.setNext( new PaymentProcessorB() ); g.setNext( new PaymentProcessorC() ); return g; }
68. Function<Payment, Payment> processorA = p -> { System.out.println( "Processor A " + p.getAmount() ); return p; }; Function<Payment, Payment> processorB = p -> { System.out.println( "Processor B " + p.getAmount() ); return p; }; Function<Payment, Payment> processorC = p -> { System.out.println( "Processor C " + p.getAmount() ); return p; };
69. Function<Payment, Payment> processorA = p -> { System.out.println( "Processor A " + p.getAmount() ); return p; }; Function<Payment, Payment> processorB = p -> { System.out.println( "Processor B " + p.getAmount() ); return p; }; Function<Payment, Payment> processorC = p -> { System.out.println( "Processor C " + p.getAmount() ); return p; }; Function<Payment, Payment> chain = processorA.andThen( processorB ).andThen( processorC ); chain.apply( new Payment( 10 ) ); //Processor A 10 //Processor B 10 //Processor C 10
70. Observer "Define a one-to-many dependency between objects so that when one object changes state, all its dependents are notified and updated automatically." GAMMA, Erich et al.
71. Exchange Rate Server Bank … Exchange Office Investor register() notify() notify() notify()
72. public interface Subject { void registerObserver(Observer observer); } public interface Observer { void notify( ExchangeRate rate ); }
73. public class Bank implements Observer { @Override public void notify( ExchangeRate rate ) { //some cool stuff here System.out.println( "Bank: " + cotacao ); } } public class Investor implements Observer { @Override public void notify( ExchangeRate rate ) { //some cool stuff here System.out.println( "Investor: " + rate ); } }
74. public class ExchangeRateServer implements Subject { private List<Observer> observers = new ArrayList<>(); public void newExchangeRate( ExchangeRate rate ) { notifyObservers( rate ); } @Override public void registerObserver( Observer observer ) { observers.add( observer ); } private void notifyObservers( ExchangeRate rate ) { observers.forEach( o -> o.notify( rate ) ); } }
75. public class Main { public static void main( String[] args ) { Bank bank = new Bank(); Investor investor = new Investor(); ExchangeRateServer server = new ExchangeRateServer(); server.registerObserver( bank ); server.registerObserver( investor ); server.newExchangeRate( new Rate( "USD", 4 ) ); } } Bank: Rate{currency='USD', valor=4} Investor: Rate{currency='USD', valor=4}
76. @Override public void registerObserver( Observer observer ) { observers.add( observer ); } public class Bank implements Observer { @Override public void notify( ExchangeRate rate ) { //some cool stuff here System.out.println( "Bank: " + rate ); } }
77. public class Main { public static void main( String[] args ) { ExchangeRateServer server = new ExchangeRateServer(); server.registerObserver( rate -> System.out.println( "Bank: " + rate ) ); server.registerObserver( rate -> { //some cool stuff here System.out.println( "Investor: " + rate ) } ); server.newExchangeRate( new ExchangeRate( "BRL", 1 ) ); } } Bank: Rate{currency='BRL', valor=1} Investor: Rate{currency='BRL', valor=1}
78. Currying
79. f(x,y) = y/x
80. f(2,3) f(x,y) = y/x
81. f(2, y) = y / 2 g(y) = f(2,y) = y/2
82. g(y) = f(2,y) = y/2 g(3) = f(2,3) = 3/2
83. CtoF(x) = x * 9/5 + 32
84. static double converter( double x, double f, double b ) { return x * f + b; } public static void main( String[] args ) { Double celsius = 15.0; Double fahrenheit = converter( celsius, 9.0 / 5, 32 ); //59 F }
85. static double converter( double x, double f, double b ) { return x * f + b; } static DoubleUnaryOperator curriedConverter( double f, double b ) { return x -> x * f + b; }
86. static DoubleUnaryOperator curriedConverter( double f, double b ) { return x -> x * f + b; } public static void main( String[] args ) { DoubleUnaryOperator convertCtoF = curriedConverter( 9.0 / 5, 32 ); convertCtoF.applyAsDouble( 35 ); //95 F convertCtoF.applyAsDouble( 15 ); //59 F }
87. static DoubleUnaryOperator curriedConverter( double f, double b ) { return x -> x * f + b; } public static void main( String[] args ) { DoubleUnaryOperator convertCtoF = curriedConverter( 9.0 / 5, 32 ); convertCtoF.applyAsDouble( 35 ); //95 F DoubleUnaryOperator convertKmToMi = curriedConverter( 0.6214, 0 ); convertKmToMi.applyAsDouble( 804.672 ); //500mi }
88. DoubleUnaryOperator convertBRLtoUSD = curriedConverter( 0.27, 0 ); double usd = convertBRLtoUSD.applyAsDouble( 100 );//27 USD DoubleUnaryOperator convertUSDtoEUR = curriedConverter( 0.89, 0 ); convertUSDtoEUR.applyAsDouble( usd ); //24.03 EUR convertBRLtoUSD.andThen( convertUSDtoEUR ).applyAsDouble( 100 ); //24.03 EUR
89. Design Patterns + Java + Funcional Programming <3
90. Thank you :) Eder Ignatowicz @ederign